import redis
import time

# 连接到Redis服务器
r = redis.Redis(host='192.168.1.111', port=6379, db=0)


def consumer():
    while True:
        # 从消息队列中阻塞地获取消息
        message = r.blpop('message_queue', timeout=0)  # timeout=0表示会阻塞
        if message:
            queue, msg = message
            msg = msg.decode('utf-8')
            print(f"已接收消息: {msg}")  # 解码字节消息


consumer()
